package com.aabbc.kafka.consumer;

import lombok.extern.slf4j.Slf4j;
import org.springframework.core.annotation.Order;
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Component;

/**
 * OrderConsumer
 *
 * @author: <a href="mailto:chenfenghai@oristartech.com">chenfenghai</a>
 * @version: 1.0
 * @date: 2019-11-27 15:59
 */
@Slf4j
@Order(10000)
@Component
public class OrderConsumer {

    @KafkaListener(topics = "topic1")
    public void onMessage(String s) {
        log.info("1consumer message: {}", s);
    }
}
